package com.flower.core_service.sources;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @ClassName CoreSink
 * @Description 消费消息通道
 * @Author 张晓焕
 * @Date 2022/8/9 22:50
 * @Version 1.0
 */
public interface CoreSink {
    String COREINPUT="coreSink";  //消费渠道 与配置文件同名

    @Input(CoreSink.COREINPUT)
    SubscribableChannel input();
}
